package com.winning.xffw.service.service;

import com.winning.xffw.service.entity.dto.BduKafkaMsg;

import java.util.List;

/**
 * @Author: shipengfei
 * @Description:
 * @Date: 2019-05-31 10:28
 */
public interface IBduKafkaMsgService {
    /**
     * 保存kafka消息记录
     *
     * @param bduKafkaMsg
     */
    void saveKafkaMsg(BduKafkaMsg bduKafkaMsg);

    List<String> queryTableList();

    List<BduKafkaMsg> queryDataMsgByTable(String tableName);

    /**
     * 处理状态更新
     *
     * @param kafkid
     * @param result：true成功、false失败
     */
    void updateStatus(String kafkid, boolean result);
}
